package com.test.myrxjava.core.map;

import com.test.myrxjava.core.Observable;
import com.test.myrxjava.core.ObservableSource;
import com.test.myrxjava.core.Observer;

public abstract class AbstractObservableWithUpStream<T,U> extends Observable<U> {

    protected final ObservableSource source;




    public AbstractObservableWithUpStream(ObservableSource source) {
        this.source = source;
    }


}
